package com.server.controller;


import com.common.Message;
import com.util.JDBCUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;

/***聊天记录控制器
 * @author lyh
 * @date 2021/10/6
 *
 * 该类作为聊天记录的控制类，完成聊天记录的相应功能
 * 将聊天记录持久化到数据库中
 */
public class historyRecord {
    Connection conn;
    PreparedStatement statement;

    //信息读取写入
    public void loadRecord(Message message) throws Exception {
        conn= JDBCUtils.getConnection();
        //信息类型，发送者，接收者，接收时间，文件名，接收内容
        String sql="insert into sys.message values(?,?,?,?,?,?)";
        statement=conn.prepareStatement(sql);

        //设置实际参数
        statement.setString(1,message.getMesType());
        statement.setString(2,message.getSender());
        statement.setString(3,message.getGetter());
        statement.setString(4,message.getSendTime());
        statement.setString(5,message.getFileName());
        statement.setString(6,message.getText());

        int res=0;
        res+=statement.executeUpdate();

        if(res>0){
            //若信息是空的，说明发送的是文件
            if(message.getText()==null){
                message.setText("文件");
            }
            System.out.println(message.getSender()+"给"
                    +message.getGetter()+"发送了:"
                    +message.getText());
        }else {
            System.out.println("信息记录失败！");
        }
    }
}
